package org.apache.flink.web.domain;

import org.apache.flink.api.common.JobID;

import java.io.Serializable;

public class SqlReq implements Serializable {
    /**
     * pipeline.name
     */
    private String name = "collect";
    /**
     * sessionId
     */
    private String sessionId = new JobID().toString();
    /**
     * sql
     */
    private String sql;
    /**
     * limit
     */
    private Integer limit;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getSessionId() {
        return sessionId;
    }

    public void setSessionId(String sessionId) {
        this.sessionId = sessionId;
    }

    public String getSql() {
        return sql;
    }

    public void setSql(String sql) {
        this.sql = sql;
    }

    public Integer getLimit() {
        return limit;
    }

    public void setLimit(Integer limit) {
        this.limit = limit;
    }
}
